package cn.ac.iie.di.ban.data.exchange.runner.slave.RocketMQHelper.receiveMQ;

import cn.ac.iie.di.datadock.rdata.exchange.client.core.session.receive.REAbstractReceiveMessageHandler;
import cn.ac.iie.di.datadock.rdata.exchange.client.v1.FailureMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MessageFailReceiver extends REAbstractReceiveMessageHandler<FailureMessage> {

    private static final Logger LOG = LoggerFactory.getLogger(MessageFailReceiver.class);

    @Override
    public boolean handle(FailureMessage msg) {
        LOG.error("formatter fuilure ! size = " + msg.getMsg().length, msg.getEx());
        return true;
    }
}
